package com.example.bpmn.kafka;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Component
public class OrderEventListener {
    
    @KafkaListener(topics = "order-events")
    public void handleOrderEvent(String message) {
        log.info("收到订单事件: {}", message);
        // 处理订单事件
    }
} 